package com.heima.stream.listener;

import org.apache.kafka.streams.kstream.KStream;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;

//监听接口
public interface WordProcess {
    @Input("word_1")
    KStream<String, String> input();
    @Output("counts_1")
    KStream<String, String> output();

}
